# -*- coding: utf-8 -*-

from jms.dwd.dwd_scan_detail_dt import jms_dwd__dwd_scan_detail_dt
from utils.operators.files_bash_operator import FilesBashOperator

jms_dwd__distcp_dwd_scan_detail_dt = FilesBashOperator(
    task_id="jms_dwd__distcp_dwd_scan_detail_dt",
    email=['zhangqinglin@jtexpress.com','yl_bigdata@yl-scm.com'],
    bash_command="jms/dwd/distcp_dwd_scan_detail_dt/execute.sh",
    # execution_timeout=max(datetime.now().replace(hour=7, minute=0, second=0) - datetime.now(), timedelta(seconds=1)),
    retries=0,
    pool='default_pool',
    pool_slots=2
)

jms_dwd__distcp_dwd_scan_detail_dt << jms_dwd__dwd_scan_detail_dt
